package com.example.consumer;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
@RabbitListener(queues = "springBootHelloWorldQueue")
public class Consumer {

    /**
     * @RabbitListener 和 @RabbitHandler 搭配使用
     * @RabbitListener可以标注在类上面，需配合 @RabbitHandler 注解一起使用
     * 标注在类上面表示当有收到消息的时候，就交给 @RabbitHandler 的方法处理，
     * 具体使用哪个方法处理，根据接收到的 message 参数类型
     * @param str
     */
    @RabbitHandler
    public void handleStr(String str){
        System.out.println("=====消费者消费消息=====");
        System.out.println(str);
    }
}
